package com.example.streamdemo.channel;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * @Package: com.example.streamdemo.channel
 * @ClassName: NewChannel
 * @Author: Think
 * @CreateTime: 2021/7/16 11:25
 * @Description:
 */
public interface NewChannel {

    String INPUT = "newInput";
    String OUTPUT = "newOutput";

    @Output(NewChannel.INPUT)
    MessageChannel output();

    @Input(NewChannel.INPUT)
    SubscribableChannel input();
}
